google.golang.org/grpc/internal/transport.http2Client.closeStream (method)
18 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L110: s.ct.closeStream(s, err, rst, rstCode, status.Convert(err), nil, false)
http2_client.go#L946: func (t *http2Client) closeStream(s *ClientStream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L1074: t.closeStream(s, err, false, http2.ErrCodeNo, st, nil, false)
http2_client.go#L1231: t.closeStream(s, io.EOF, true, http2.ErrCodeFlowControl, status.New(codes.Internal, err.Error()), nil, false)
http2_client.go#L1239: t.closeStream(s, st.Err(), true, http2.ErrCodeProtocol, st, nil, true)
http2_client.go#L1268: t.closeStream(s, io.EOF, rstStream, http2.ErrCodeNo, status.New(codes.Internal, "server closed the stream without sending trailers"), nil, true)
http2_client.go#L1296: t.closeStream(s, st.Err(), false, http2.ErrCodeNo, st, nil, false)
http2_client.go#L1433: t.closeStream(stream, errStreamDrain, false, http2.ErrCodeNo, statusGoAway, nil, false)
http2_client.go#L1483: t.closeStream(s, st.Err(), true, http2.ErrCodeProtocol, st, nil, false)
http2_client.go#L1491: t.closeStream(s, se.Err(), true, http2.ErrCodeFrameSize, se, nil, endStream)
http2_client.go#L1501: t.closeStream(s, st.Err(), true, http2.ErrCodeProtocol, st, nil, true)
http2_client.go#L1538: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1573: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1580: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1607: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, true)
http2_client.go#L1617: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1667: t.closeStream(s, io.EOF, rstStream, http2.ErrCodeNo, status, mdata, true)
http2_client.go#L1731: t.closeStream(s, status.Error(code, msg), true, http2.ErrCodeProtocol, status.New(code, msg), nil, false)